#include "comm.hpp"
#include <unistd.h>
#include "ser.hpp"

int main()
{
    Share_Mem sm(default_path, proj_id, CREATER);
    // 创建管道文件
    NamedPipe fif0(".", SER_FIFO);
    // 打开管道文件
    File_operate fifo(".", SER_FIFO);

    fifo.Open_for_Read();

    sm.Attch();
    char *shm = (char *)sm.Virtual_address();
    while (true)
    {
        // 读数据  这里默认会阻塞
        if (fifo.Read())
        {
            printf("client  :  %s\n", shm);
            sleep(1);
        }
        else
            break;
    }
    // 关闭文件
    fifo.Close();
    return 0;
}